/**
 * 
 * 可读流
 * 
 */

 let fs = require("fs")
// 创建一个可读流
let rs = fs.createReadStream('./1.txt',{
    highWaterMark: 3,
    flags: "r",
    mode: 0o666,
    encoding: 'utf8',
    start: 3,
    end: 8  //唯一一个包括结束索引的
})
rs.setEncoding("utf8")
// 监听data事件 当一旦开始监听data事件的时候，流就开始读文件的内容并且发射data
rs.on('data', function(data){
    console.log(data)
    rs.pause()
    setTimeout(()=>{
        rs.resume()
    }, 2000)
})
rs.on("end", function(){
    console.log("读完了")
})
rs.on("error", function(){
    console.log("error")
})
// 文件流 open 事件，close事件，文件已被关闭

// 希望流有一个暂停和恢复触发的机制
// rs.pause() 暂停读取和发射data事件 rs.resume()恢复读取触发data事件

